package com.wanqian.redis.activemq;

import org.apache.activemq.broker.BrokerService;

/**
 * @Author: wanqian
 * @Date: 2021/3/13 14:42
 */
public class ActiveMQBroker {

    public static void main(String[] args) throws Exception {
        //创建一个嵌入式的MQ实例
        BrokerService brokerService = new BrokerService();
        brokerService.setPopulateJMSXUserID(true);
        brokerService.addConnector("tcp://127.0.0.1:61616");
        brokerService.start();
    }
}
